# 主程序

from celery import Celery

# 创建celery示例对象
app = Celery('luffy')

# 如果celery需要在任务中需要调用其他框架的内部对象，则需要对响应的框架初始化
import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'luffy_city.settings.dev')
django.setup()

# 通过app对象加载配置
app.config_from_object("my_celery.config")

# 自动搜索并加载任务
# 参数必须是一个列表，里面的每一个任务都是任务的路径名称
# app.autodiscover_tasks(['任务组一','任务组二',...])
app.autodiscover_tasks(['my_celery.sms', 'my_celery.email'])

# 启动Celery的命令
# 强烈建议切换目录到项目的根目录下启动celery
# celery -A my_celery.main worker -l info -P eventlet
